//package com.rp.article.stream;
//
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.annotation.StreamListener;
//import org.springframework.stereotype.Component;
//
///**
// * 构建消费端
// */
//@Component
//@EnableBinding(MyStreamChannel.class)
//public class MyStreamConsumer {
//
//    /**
//     * 监听并且实现消息的消费和相关的业务处理
//     * @param msg
//     */
//    @StreamListener(MyStreamChannel.INPUT)
//    public void receiveMsg(String msg){
//        System.out.println("==>" + msg);
//    }
//}
